package org.yray.io.rocketmqdemo.listener;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;

public interface IMqMsgListener {

     ConsumeConcurrentlyStatus doMsg(String body);
}
